#!/usr/bin/python
# author Yu
# 2023年06月21日
import os
import random
import time
from multiprocessing import Pool
def worker(msg):
    print(f'进程id{os.getpid()},任务编号{msg}')#打印进程id
    time.sleep(random.random())#模拟实际干活时间
    print(f"任务完成,{msg}")

if __name__ == '__main__':
    po=Pool(3)#创建进程池，最多同时执行3个进程
    for i in range(6):
        po.apply_async(worker,(i,))#父进程是生产者，子进程是消费者
    po.close()
    po.join()